home *** CD-ROM | disk | FTP | other *** search
/ QRZ! Ham Radio 1 / QRZ Ham Radio Callsign Database - December 1993.iso / ucsd / packet / tcpip / sys5 / iscwmpst.z / iscwmpst / tcp / isc-src / convers / convers.c < prev    next >
Encoding:
C/C++ Source or Header  |  1991-10-29  |  3.9 KB  |  164 lines
  1. static char  rcsid[] = "@(#) $Header: convers.c,v 1.7 89/05/03 20:14:27 dk5sg Exp $";
  2.  
  3. #include <sys/types.h>
  4.  
  5. #include <signal.h>
  6. #include <stdio.h>
  7. #include <sys/socket.h>
  8. #include <termio.h>
  9. #include <time.h>
  10.  
  11. extern char  *getenv();
  12. extern char  *optarg;
  13. extern int  optind;
  14. extern struct sockaddr *build_sockaddr();
  15. extern void exit();
  16. extern void perror();
  17.  
  18. static struct termio prev_termio;
  19.  
  20. /*---------------------------------------------------------------------------*/
  21.  
  22. #if (defined(HPUX)||defined(BSD))
  23. static void sigpipe_handler(sig, code, scp) 
  24. int  sig, code; 
  25. struct sigcontext *scp;
  26. { 
  27.   scp->sc_syscall_action = SIG_RETURN; 
  28. } 
  29. #endif
  30. /*---------------------------------------------------------------------------*/
  31.  
  32. static void stop(arg)
  33. char  *arg;
  34. {
  35.   if (arg) perror(arg);
  36.   ioctl(0, TCSETA, &prev_termio);
  37.   exit(0);
  38. }
  39.  
  40. /*---------------------------------------------------------------------------*/
  41.  
  42. main(argc, argv)
  43. int  argc;
  44. char  **argv;
  45. {
  46. #if (defined(HPUX)||defined(BSD))
  47.   char  *server = "unix:/tcp/sockets/convers";
  48. #else
  49.   char  *server = "*:3600";
  50. #endif
  51.   char  buffer[2048];
  52.   char  c;
  53.   char  inbuf[2048];
  54.   char  outbuf[2048];
  55.   int  addrlen;
  56.   int  ch;
  57.   int  channel = 0;
  58.   int  echo;
  59.   int  errflag = 0;
  60.   int  i;
  61.   int  incnt = 0;
  62.   int  mask;
  63.   int  outcnt = 0;
  64.   int  size;
  65.  
  66. #if (defined(HPUX)||defined(BSD))
  67.   struct sigvec vec; 
  68. #endif
  69.   struct sockaddr *addr;
  70.   struct termio curr_termio;
  71.  
  72. #if (defined(HPUX)||defined(BSD))
  73.   vec.sv_mask = vec.sv_flags = 0; 
  74.   vec.sv_handler = sigpipe_handler; 
  75.   sigvector(SIGPIPE, &vec, (struct sigvec *) 0);
  76. #endif
  77.  
  78.   if (ioctl(0, TCGETA, &prev_termio)) stop(*argv);
  79.   if (ioctl(0, TCGETA, &curr_termio)) stop(*argv);
  80.   echo = curr_termio.c_lflag & ECHO;
  81.   curr_termio.c_lflag = 0;
  82.   curr_termio.c_cc[VMIN] = 1;
  83.   curr_termio.c_cc[VTIME] = 0;
  84.   if (ioctl(0, TCSETA, &curr_termio)) stop(*argv);
  85.  
  86.   while ((ch = getopt(argc, argv, "c:s:")) != EOF)
  87.     switch (ch) {
  88.     case 'c':
  89.       channel = atoi(optarg);
  90.       break;
  91.     case 's':
  92.       server = optarg;
  93.       break;
  94.     case '?':
  95.       errflag = 1;
  96.       break;
  97.     }
  98.  
  99.   if (errflag || optind < argc || !(addr = build_sockaddr(server, &addrlen))) {
  100.     fprintf(stderr, "usage: convers [-c channel] [-s host:service]\n");
  101.     stop(0);
  102.   }
  103.  
  104.   close(3);
  105.   if (socket(addr->sa_family, SOCK_STREAM, 0) != 3) stop(*argv);
  106.   if (connect(3, addr, addrlen)) stop(*argv);
  107.  
  108.   sprintf(inbuf, "/NAME %s %d\n", getenv("LOGNAME"), channel);
  109.   if (write(3, inbuf, (unsigned) strlen(inbuf)) < 0) stop(*argv);
  110.  
  111.   for (; ; ) {
  112.     mask = 011;
  113.     select(4, &mask, 0, 0, (struct timeval *) 0);
  114.     if (mask & 1) {
  115.       do {
  116.     if ((size = read(0, buffer, sizeof(buffer))) <= 0) stop(0);
  117.     for (i = 0; i < size; i++) {
  118.       c = buffer[i];
  119.       if (c == '\r') c = '\n';
  120.       if (c == prev_termio.c_cc[VERASE]) {
  121.         if (incnt) {
  122.           incnt--;
  123.           if (echo && write(1, "\b \b", 3) < 0) stop(*argv);
  124.         }
  125.       } else if (c == prev_termio.c_cc[VKILL]) {
  126.         for (; incnt; incnt--)
  127.           if (echo && write(1, "\b \b", 3) < 0) stop(*argv);
  128.       } else if (echo && c == 18) {
  129.         if (write(1, "^R\n", 3) < 0) stop(*argv);
  130.         if (write(1, inbuf, (unsigned) incnt) < 0) stop(*argv);
  131.       } else {
  132.         inbuf[incnt++] = c;
  133.         if (echo && write(1, &c, 1) < 0) stop(*argv);
  134.       }
  135.       if (c == '\n' || incnt == sizeof(inbuf) - 1) {
  136.         if (*inbuf == '!') {
  137.           inbuf[incnt] = '\0';
  138.           if (ioctl(0, TCSETA, &prev_termio)) stop(*argv);
  139.           system(inbuf + 1);
  140.           if (ioctl(0, TCSETA, &curr_termio)) stop(*argv);
  141.           if (write(1, "!\n", 2) < 0) stop(*argv);
  142.         } else {
  143.           if (write(3, inbuf, (unsigned) incnt) < 0) stop(*argv);
  144.         }
  145.         incnt = 0;
  146.       }
  147.     }
  148.       } while (incnt);
  149.     } else {
  150.       size = read(3, buffer, sizeof(buffer));
  151.       if (size <= 0) stop(0);
  152.       for (i = 0; i < size; i++) {
  153.     c = buffer[i];
  154.     if (c != '\r') outbuf[outcnt++] = c;
  155.     if (c == '\n' || outcnt == sizeof(outbuf)) {
  156.       if (write(1, outbuf, (unsigned) outcnt) < 0) stop(*argv);
  157.       outcnt = 0;
  158.     }
  159.       }
  160.     }
  161.   }
  162. }
  163.  
  164.